Ich arbeite mit dem Wiederholungsoperator in RxSwift. Gemäß seiner Dokumentation "abonniert" es die Quelle, die beobachtet werden kann, wenn ein Fehler auftritt. Das ist alles schön und gut. Ich bin mir jedoch nicht ganz sicher, wie ich über die "beobachtbare Quelle" nachdenken soll, wenn sie heiße Observable oder eine Mischung aus heißen / kalten Observablen enthält. Ein Beispiel, bei dem ich mir sicher bin: let coldObservable = Observable.interval (.seconds (1), Scheduler: MainScheduler.instance) let kaltObservableRetry = kaltObservable.flatMapLatest {num in if num% 3 == 0 {return .just (num)} sonst {return .error ()} }} .retry (2) // retry schließt den ursprünglichen Versuch ein coldObservableRetry.subscribe (onNext: {print ($ 0)}) // druckt 1, 2, 1, 2 vor dem Auslaufen. Ein Beispiel, bei dem ich mir nicht sicher bin: let hotObservable = Observable .interval (.seconds (1), Scheduler: MainScheduler.instance) .publish (). connect () let hotObservableRetry = hotObservable.flatMapLatest {num in if num% 3 == 0 {return .just (num)} sonst {return .error ()} }} .retry (2) hotObservableRetry.subscribe (onNext: {print ($ 0)}) // Was passiert hier? Ein weiteres Beispiel, bei dem ich mir nicht sicher bin: let coldObservable = Observable .interval (.seconds (1), Scheduler: MainScheduler.instance) let delayHotObservable = Observable .interval (.seconds (1), Scheduler: MainScheduler.instance) .delay (Millisekunden (100), Scheduler: MainScheduler.instance) .publish (). connect () let blendObservableRetry = Observable.combineLatest (kaltObservable, verzögertHotObservable) .map {$ 0 + $ 1} .flatMapLatest {num in if num% 3 == 0 {return .just (num)} sonst {return .error ()} }} .retry (5) mixObservableRetry.subscribe (onNext: {print ($ 0)}) // Was passiert hier? Was bedeutet es überhaupt, einen Mähdrescher mit einem heißen und einem kalten Observable erneut zu abonnieren? Ein weiteres Beispiel, bei dem ich mir nicht sicher bin: let coldObservable = Observable .interval (.seconds (1), Scheduler: MainScheduler.instance) let hotObservable = Observable .interval (.seconds (1), Scheduler: MainScheduler.instance) .publish (). connect () let mixObservable2Retry = coldObservable.flatMapLatest {_ in hotObservable} .flatMapLatest {num in if num% 3 == 0 {return .just (num)} sonst {return .error ()} }} .retry (2) mixObservable2Retry.subscribe (onNext: {print ($ 0)}) // Was passiert hier?
2021-02-26 08:16:59
Viele Ihrer Beispiele werden nicht kompiliert. Sie erhalten also einen Kompilierungsfehler. :-) Aber um die gestellte Frage zu beantworten ...
Es gibt einige wichtige Dinge zu beachten.
Jeder Operator abonniert seine Quell-Observable (s) und generiert eine neue Observable.
Wenn ein kaltes Observable abonniert wird, gibt es 0 ... N nächste Ereignisse und dann ein Stoppereignis (das entweder abgeschlossen oder fehlerhaft ist) aus. Es gibt jedem Abonnement seine eigenen Ereignisse.
Heiße Observable werden erst gesendet, wenn ihre Verbindung aufgerufen wird. Alle Abonnements teilen sich die gleichen Ereignisse.
In diesem Fall ist das Debuggen Ihr Freund.
Für Ihr erstes Beispiel sind Sie sich also nicht sicher (angepasst, damit es mit einigen hinzugefügten Debug-Operatoren kompiliert und ausgeführt wird):
func example () {
let hotObservable = Observable .interval (.seconds (1), Scheduler: MainScheduler.instance)
.debug ("vor der Veröffentlichung")
.veröffentlichen()
let hotObservableRetry = hotObservable
.debug ("nach Veröffentlichung")
.map {(num) -> Int in
guard num% 3! = 0 else {throw MyError ()}
Rückgabe num
}}
.debug ("nach Karte")
.retry (2)
.debug ("nach erneutem Versuch")
_ = hotObservableRetry.subscribe ()
_ = hotObservable.connect ()
}}
Erzeugt die folgende Ausgabe.
Im Folgenden finden Sie einige wichtige Informationen zur Ausgabe, die beim Lernprozess hilfreich sind.
Die Abonnements erfolgen in umgekehrter Reihenfolge.
Sobald der erste Fehler ausgegeben wird, abonniert der Wiederholungsoperator das Observable des Kartenoperators erneut, das das Observable des Publish erneut abonniert. Da die beobachtbare Größe der Veröffentlichung heiß ist, stoppt die Kette der erneuten Anmeldung dort. Das Observable des Timers wird nicht erneut abonniert.
Das Obige sind die wichtigsten Punkte, die Sie verstehen müssen, um diese Frage zu beantworten.
nach erneutem Versuch -> abonniert
nach Karte -> abonniert
nach der Veröffentlichung -> abonniert
vor der Veröffentlichung -> abonniert
vor der Veröffentlichung -> Ereignis weiter (0)
nach der Veröffentlichung -> Ereignis weiter (0)
nach Karte -> Ereignisfehler (MyError ())
nach map -> isDisposed
nach der Veröffentlichung -> isDisposed
nach Karte -> abonniert
nach der Veröffentlichung -> abonniert
vor der Veröffentlichung -> Ereignis weiter (1)
nach der Veröffentlichung -> Ereignis weiter (1)
nach Karte -> Ereignis weiter (1)
nach erneutem Versuch -> Ereignis weiter (1)
vor der Veröffentlichung -> Ereignis weiter (2)
nach der Veröffentlichung -> Ereignis weiter (2)
nach Karte -> Ereignis weiter (2)
nach erneutem Versuch -> Ereignis weiter (2)
vor der Veröffentlichung -> Ereignis weiter (3)
nach der Veröffentlichung -> Ereignis weiter (3)
nach Karte -> Ereignisfehler (MyError ())
nach erneutem Versuch -> Ereignisfehler (MyError ())
nach erneutem Versuch -> isDisposed
nach map -> isDisposed
nach der Veröffentlichung -> isDisposed
vor der Veröffentlichung -> Event next (4)
vor der Veröffentlichung -> Ereignis weiter (5)
vor der Veröffentlichung -> Event next (6)
...
Im nächsten Beispiel, das Sie gezeigt haben, abonniert der Operator combinLatest das Hot Observable erneut, das Connectable Observable jedoch nicht erneut die Quelle.
7
|
Deine Antwort
StackExchange.ifUsing ("Editor", function () {
StackExchange.using ("externalEditor", function () {
StackExchange.using ("Snippets", function () {
StackExchange.snippets.init ();
});
});
}, "Code Ausschnitte");
StackExchange.ready (function () {
var channelOptions = {
Tags: "" .split (""),
id: "1"
};
initTagRenderer ("". split (""), "" .split (""), channelOptions);
StackExchange.using ("externalEditor", function () {
// Editor muss nach Snippets ausgelöst werden, wenn Snippets aktiviert sind
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using ("Snippets", function () {
createEditor ();
});
}}
sonst {
createEditor ();
}}
});
Funktion createEditor () {
StackExchange.prepareEditor ({
useStacksEditor: false,
heartbeatType: 'Antwort',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: wahr,
showLowRepImageUploadWarning: true,
Ruf zu PostImages: 10,
bindNavPrevention: true,
Postfix: "",
imageUploader: {
brandingHtml: "Powered by \ u003ca href =" https: //imgur.com/ "u003e" u003csvg class = "svg-icon" width = "50" height = "18" viewBox = "0 0 50 18" fill = "none" xmlns = "http: //www.w3.org/2000/svg" 46,2665 7,94324 47,1084 7.58816C47.4091 7,46349 47,7169 7,36433 48,0099 7.26993C48.9099 6,97997 49,672 6,73443 49,672 5.93063C49.672 5,22043 48,9832 4,61182 48,1414 4.61182C47.4335 4,61182 46,7256 4,91628 46,0943 5.50789C45.7307 4,9328 45,2525 4,66231 44,6595 4.66231C43.6264 4,66231 43,1481 5,28821 43.1481 6.59048V11.9512C43.1481 13.2535 43.6264 13.8962 44.6595 13.8962C45.6924 13.8962 46.1709 13.2535 46.1709 11.9512V9.17788Z 41.5985 12.6954 41.5985 10.1419V6.59049C41.5985 5.28821 41.1394 4.66232 40.1061 4.66232C39.0732 4.66232 38.5948 5.28821 38.5948 6.59049V9.60062C38.5948 10.8521 38.2696 11.5455 37.0455 11.545 5. 521 35.4954 9.60062V6.59049C35.4954 5.28821 35.0173 4.66232 34.0034 4.66232C32.9703 4.66232 32.492 5.28821 32.492 6.59049V10.1419Z "/ \ u003e" = "M25.6622 17.6335C27.8049 17.6335 29.3739 16.9402 30.2537 15.6379C30.8468 14.7755 30.9615 13.5579 30.961511.9512V6.59049C30.9615 5.28821 30.4833 4.66231 29.4502 4.66231C28.9913 4.66231 28.4555 4.94978 28.1109 5.50789C27.499 4.86533 26.7335 4.56087 25.7005 4.56087C23.1369 4.56087 21.0134 6.53.413 12.6616C28.1109 12.7229 28.1161 12.7799 28.121 12.8346C28.1256 12.8854 28.1301 12.9342 28.1301 12.983C28.1301 14.4373 27.2502 15.2321 25.777 15.2321C24.8349 15.2321 24.1352 14.9821 23.5662 .2429 16.7375 22.9072 17.6335 25.6622 17.6335ZM24.1317 9.27932C24.1317 7.94324 24.9928 7.09766 26.1024 7.09766C27.2119 7.09766 28.0918 7.94324 28.0918 9.27932C28.0918 10.6321 27.2311 11.5116 u003cpath d = "M16.8045 11.9512C16.8045 13.2535 17.2637 13.8962 18.2965 13.8962C19.3298 13.8962 19.8079 13.2535 19.8079 11.9512V8.12928C19.8079 5.82936 18.4879 4.62866 16.4027 4.62866C15.1594 4.62866 14.279 4.98375 13.3609 5.88013C12.653 5.05154 11.6581 4.62866 10.3573 4.62866C9.34336 4.62866 8.57809 4.89931 7.9466 5.5079C7.58314 4.932.6 5,47873 13,8962 6,51203 13,8962C7,54479 13,8962 8,0232 13,2535 8,0232 11,9512V8,90741C8,0232 7,58817 8,44431 6,91179 9,53458 6,91179C10,5104 6,91179 10,893 7,58817 10,893 8,9213 90741C13.9157 7.58817 14.3365 6.91179 15.4269 6.91179C16.4027 6.91179 16.8045 7.58817 16.8045 8.94108V11.9512Z "/ \ u003e" V11.9512C0.313354 13.2535 0.791758 13.8962 1.82471 13.8962C2.85798 13.8962 3.31675 13.2535 3.31675 11.9512V6.59049Z "M1.87209 0.400291C0.843612 0.400291 0 1,1159 0 1,98861C0 2,87869 0,822846 3,57676 1,87209 3,57676C2,90056 3,57676 3,7234 2,87869 3,7234 1,98861C3,7234 1,1159 2,90056 0,400291 1,87209 0,400291Z \ u003e ",
contentPolicyHtml: "Benutzerbeiträge, lizenziert unter \ u003ca href = \" https: //stackoverflow.com/help/licensing \ "\ u003ecc by-sa \ u003c / a \ u003e \ u003ca href = \" https://stackoverflow.com / legal / content-policy \ "\ u003e (Inhaltsrichtlinie) \ u003c / a \ u003e",
allowUrls: true
},
onDemand: wahr,
discardSelector: ".discard-answer"
, instantShowMarkdownHelp: true, enableTables: true, enableSnippets: true
});
}}
});
Vielen Dank, dass Sie eine Antwort auf Stack Overflow gegeben haben!
Bitte beantworten Sie die Frage unbedingt. Geben Sie Details an und teilen Sie Ihre Forschung!
Aber vermeiden Sie ...
Um Hilfe bitten, Klarheit schaffen oder auf andere Antworten antworten.
Stellungnahmen auf der Grundlage von Meinungen abgeben; Unterstützen Sie sie mit Referenzen oder persönlichen Erfahrungen.
Weitere Informationen finden Sie in unseren Tipps zum Schreiben großartiger Antworten.
Entwurf gespeichert
Entwurf verworfen
Anmelden oder anmelden
StackExchange.ready (function () {
StackExchange.helpers.onClickDraftSave ('# login-link');
});
Melden Sie sich mit Google an
Melde dich über Facebook an
Melden Sie sich mit E-Mail und Passwort an
einreichen
Post als Gast
Name
Email
Erforderlich, aber nie gezeigt
StackExchange.ready (
function () {
StackExchange.openid.initPostLogin ('. New-post-login', 'https% 3a% 2f% 2fstackoverflow.com% 2fquestions% 2f64950463% );
}}
);
Post als Gast
Name
Email
Erforderlich, aber nie gezeigt
Veröffentlichen Sie Ihre Antwort
Verwerfen
Wenn Sie auf "Antwort posten" klicken, stimmen Sie unseren Nutzungsbedingungen, Datenschutzbestimmungen und Cookie-Richtlinien zu
Nicht die Antwort, die Sie suchen? Durchsuchen Sie andere Fragen mit dem Tag ios swift5 rx-swift oder stellen Sie Ihre eigene Frage.